ea76ac2badcda417ad1ba9fb9955fca5438c8a3a,src/org/jgroups/protocols/UDP.java,UcastReceiver,run,#,863
Before Change
final DatagramPacket packet=new DatagramPacket(receive_buf, receive_buf.length);
while(running && thread != null && sock != null) {
try {
sock.receive(packet);
len=packet.getLength();
if(len > receive_buf.length) {
if(log.isErrorEnabled())
log.error("size of the received packet (" + len + ") is bigger than allocated buffer (" +
receive_buf.length + "): will not be able to handle packet. " +
"Use the FRAG2 protocol and make its frag_size lower than " + receive_buf.length);
}
sender_addr=packet.getAddress();
sender_port=packet.getPort();
offset=packet.getOffset();
sender=new IpAddress(sender_addr, sender_port);
receive(local_addr, sender, receive_buf, offset, len);
}
catch(SocketException sock_ex) {
if(log.isDebugEnabled()) log.debug("unicast receiver socket is closed, exception=" + sock_ex);
After Change
}
public void run() {
final byte receive_buf[]=new byte[65535];
final DatagramPacket packet=new DatagramPacket(receive_buf, receive_buf.length);
while(running) {
try {
socket.receive(packet);
int len=packet.getLength();
if(len > receive_buf.length) {
if(log.isErrorEnabled())
log.error("size of the received packet (" + len
+ ") is bigger than "
+ "allocated buffer ("
+ receive_buf.length
+ "): will not be able to handle packet. "
+ "Use the FRAG2 protocol and make its frag_size lower than "
+ receive_buf.length);
}
receive(dest,
new IpAddress(packet.getAddress(), packet.getPort()),
receive_buf,
packet.getOffset(),
len);
}
catch(IOException sock_ex) {
boolean socketConnected = (socket != null && socket.isConnected());